package com.qriver.cloud.consumer;

import com.sun.istack.internal.logging.Logger;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;


@EnableBinding(Sink.class)
public class ConsumerController {

    Logger logger = Logger.getLogger(ConsumerController.class);


    @StreamListener(Sink.INPUT)
    public void consumer(Object payload) {
        logger.info("consumer: " + payload);
    }
}
